package com.cloud.streamconsumerself.error;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * Created by wuxiang on 2019/2/20 16:59
 *
 * 定义两个通道，一个输入，一个输出，并且指向相同的Topic，实现自己消费自己
 */
public interface TestTopic1 {

    String OUTPUT = "example-topic";
    String INPUT = "example-topic";

    @Output(value = OUTPUT)
    MessageChannel output();

    @Input(value = INPUT)
    SubscribableChannel input();

}
